#!/usr/bin/env node

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://admin:clwy1234@localhost', function (error0, connection) {
  if (error0) {
    throw error0;
  }
  connection.createChannel(function (error1, channel) {
    if (error1) {
      throw error1;
    }
    // 队列的名字
    var queue = 'hello';
    var msg = `你好长了唯一`;

    // 创建一个队列。如果队列不存在，则创建一个队列，如果已经存在，，则不会创建
    // durable: 表示队列是否持久化，如果设置为true，则重启后队列不会消失
    channel.assertQueue(queue, {
      durable: false,
    });

    console.log(' [*] Waiting for messages in %s. To exit press CTRL+C', queue);

    // 发送消息队列
    // queue: 要发送的队列名字
    // content: 要发送的消息内容
    channel.sendToQueue(queue, Buffer.from(msg));
    console.log('[x]发送了：%s', msg);

    // channel.consume(queue, function(msg) {
    //     console.log(" [x] Received %s", msg.content.toString());
    // }, {
    //     noAck: true
    // });
  });

  setTimeout(function () {
    connection.close();
    process.exit(0);
  }, 500);
});
